package com.kai.service.mqtt.consumer;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import java.nio.charset.StandardCharsets;

@Slf4j
public class TestConsumer extends MessageConsumerAbstract {

    @Override
    public void consume(MqttMessage mqttMessage) {
        String payload = new String(mqttMessage.getPayload(), StandardCharsets.UTF_8);

        log.info("payload: {}", payload);
    }

}
